בונים פריימוורק - מודלים

/*
     * @param (string) $name the name of model
     * @param (model) $model object model
     * set the path of the model folder
     * set the object model on $model
     */

    public function loadModel($name)
    {
       
        $path = APPLICATION . DS . 'models' . DS . $name . '.php';

        if (file_exists($path)) {

            require($path);

            $modelname = ucfirst($name) . '_Model';
            $this->model = new $modelname();
        }

    }

<?php

class Framework_Model
{

    public $db;

    function __construct()
    {
//use the database class for use on all models
            $this->db = Framework_Model_Database(get_child_name());
    }

}

<?php

/*
 * **************************
 *     Sidox db model      *
 * **************************
 *
 * how to use:
 * 1)connected to sql server
 * demo for mysql:
 *      $obj = new Sidox_Model_Database('table'(=null));
 * 2)set table
 *      $obj->table = "tablename";
 * 3)for add new information in db use
 *      $obj->dbColum = 'x';
 *      $obj->dbColum2 = 'y';
 *      $obj->save();
 * 4)for update information in db use
 *      $obj->dbColum = 'y';
 *      $obj->dbColum2 = 'x';
 *      $obj->save('dbColum = x','dbColum2 = y');
 * 5)delete information
 *      $obj->delete('dbColum = y','dbColum2 = x');
 * 6)get information
 *      $obj->getRows('dbColum = y','dbColum2 = x');
 *      $obj->getRows(); //get all
 * 7)order by and limit
 *      $obj->order('dbColum','DESC')->limit(0,2)->getRows('dbColum = y','dbColum2 = x');
 *      $obj->order('dbColum','DESC')->limit(0,2)->getRows();
 */

class Framework_Model_Database extends PDO {
    /*
     * @param (string) $_data Linking the database with data
     */

    private $_data = null;
    /*
     * @param (string) $_scan scan in db
     */
    private $_scan = null;
    /*
     * @param (string) $table database table
     */
    public $table;

    /*
     * use parent construct and set table
     */
    function __construct($table = null) {
        parent::__construct(General::Conf('DBtype').':host='.General::Conf('DBhost').';dbname='.General::Conf('DBname'), General::Conf('DBuser'), General::Conf('DBpassword'));
        $this->table = $table;
    }

    /*
     * save params in $_data
     * @param $name name of db column
     * @param $value the colum value
     */

    function __set($name, $value) {

        if ($this->_action == 'update') {
            $this->_data[] = '`' . $name . '` = \'' . $value . '\'';
        }
        $this->_data[$name] = " '$value' ";
    }

    /*
     * add mode: save in db new information
     * update mode: update the information
     * @param $_data save the information
     * @param $_update save the mode of function (true = update, false = add)
     * @param func_args where to scan for update
     * @param $table db table
     * @param $rtn return data
     * @return false or query
     */

    public function save() {
        $rtn = false;
        if ((empty($this->_data)) && (empty($this->table))) {
            return false;
        } elseif (func_num_args() > 0) {
            //action update
            $update = null;
            foreach ($this->_data as $key => $value) {
                if (empty($update)) {
                    $update = " `{$key}` = '{$value}'";
                    continue;
                }
                $update .= " , `{$key}` = '{$value} '";
            }
            $rtn = $this->query(
                    'UPDATE `' . $this->table . '` SET ' .
                    $update . $this->scanWhere(func_get_args())
            );
        } else {
            //action add
            $rtn = $this->query(
                    'INSERT INTO `' . $this->table . '` (
                    ' . implode(' , ', array_keys($this->_data)) . ' ) VALUES (
                    ' . implode(' , ', $this->_data) . ' )'
            );
        }
        $this->_data = null;
        return $rtn;
    }

    /*
     * delete db row
     * @param func_args
     * @return the query connection
     */

    public function delete() {
        if (func_num_args() > 0)
            return $this->query(
                            'DELETE FROM `' . $this->table .
                            $this->scanWhere(func_get_args())
            );
    }

    /*
     * get DB rows
     * @param func_args or null
     * @return the query connection
     */

    public function getRows() {
        $sql = 'SELECT * FROM `' . $this->table . '` ';

        if (func_num_args() > 0)
            $sql .= $this->scanWhere(func_get_args());
        if (!empty($this->_sets)) {

            $sql .= " " . $this->_sets;
            unset($this->_sets);
        }

        unset($this->_scan);
        return $this->query($sql);
    }

    /*
     * Order By
     * @param string $order what order
     * @param string $type is ASC or DESC
     * @param $_sets test if set if true function die
     * @return $this
     */

    public function order($order, $type = 'ASC') {
        if (isset($this->_sets['order'])) {
            return false;
        }
        $this->_scan .= ' ORDER BY ' . $order . ' ' . $type . ' ';

        $this->_sets['order'] = null;
        return $this;
    }

    /*
     * limit list
     * @param int $limit start limit list or mach of limit
     * @param int $endLimit end the limit list
     * @param $_sets test if set if true function die
     * @return $this
     */

    public function limit($limit, $endLint = null) {
        if (isset($this->_sets['limit'])) {
            return false;
        }
        if (!empty($endLint))
            $this->_scan .= ' LIMIT ' . $limit . ',' . $endLint;
        else
            $this->_scan .= ' LIMIT ' . $limit;

        $this->_sets['limit'] = null;
        return $this;
    }

    /*
     * @param Array $scanArgs where scan
     * @return where to scan
     */

    private function scanWhere($scanArgs) {
        for ($i = 0; $i < sizeof($scanArgs); $i++) {
            sscanf($scanArgs[$i], '%s %s %s', $key, $operator, $value);
            $scanArgs[$i] = ' `' . $key . '` ' . $operator . ' \'' . $value . '\'';
        }
        return ' WHERE ' . implode(' AND ', $scanArgs);
    }

}

function runController($name, $method = NULL) {
        /*
         * cheak if controller exists
         * TRUE:(controller not exists)
         * run diagnostics
         * go to error page -> move to default page
         */
        $Controller = ucfirst($name) . "Controller";
        $dirController = APPLICATION . 'controllers' . DS .
                $Controller . '.php';
        if (!(file_exists($dirController))) {
            //if file not exists it's 404 page
            echo "404"; //you can make 404 page controller or header...
            return FALSE;
        }

        /*
         * run contoller
         */
        require $dirController;

        $Controller = new $Controller;
        $Controller->loadModel($name); //load the model

        //cheak if meathod exists
        if (!(method_exists($Controller, $method)))
            $method = "Main";   //method not exist set defualt
        $Controller->{$method}();   //run action
    }

<?php

class Main_Model extends Framework_Model
{

    public function cheakuser()
    {
        if (isset($_POST['username'])
             if ($_POST['username'] == null)
               echo 'the username can't be empty';
    }
}

$this->mainModel = $this->loadModel('main');
$this->mainModel->cheakuser();